package com.lxb.demo01

import org.apache.flink.streaming.api.scala._;

/**
 * @author: albert
 * @date: 2021/1/18 14:31
 * @description:
 */
object Demo2 {
  def main(args: Array[String]): Unit = {

    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment

    env.setParallelism(1)



  }
}
